###
 # @Company: TWL
 # @Author: xue jian
 # @Email: xuejian@kanzhun.com
 # @Date: 2020-05-21 20:45:48
### 
#!/bin/sh
#riqizizeng
datebeg="2020-05-08"
dateend="2020-05-09"
#read datebeg
#read dateend
beg_s=`date -d "$datebeg" +%s`
end_s=`date -d "$dateend" +%s`
while [ "$beg_s" -le "$end_s" ]
do
tmp=`date -d @$beg_s +"%Y-%m-%d"`
echo $tmp

# # b端开聊实时流
# del_file=/basicdata/kafka/boss/arc/recommender/bossrec_fid_flow/ds=$tmp
# hadoop fs -rm -r $del_file


#B 端达成数据流 
del_file=/basicdata/kafka/boss/arc/recommender/bossrec_success_fid_flow/ds=$tmp/*
# echo $del_file
hdfs dfs -getmerge $del_file /data3/training_data/arc_six/bossrec_success_fid_flow/$tmp

# # C 端开聊数据流
# del_file=/basicdata/kafka/boss/arc/recommender/geekrec_fid_flow/ds=$tmp
# hadoop fs -rm -r $del_file


beg_s=$((beg_s+86400))
done